package com.bossien.flink.common;

import com.bossien.flink.interfaces.IExcutionPostResult;
import lombok.Data;
import lombok.experimental.Accessors;

/**
 * @author 胡春林
 * 本地环境结果push
 */
@Data
@Accessors(chain = true)
public class LocalEnviromentResult<T> implements IExcutionPostResult {

    private T result;

    //发送者队列名
    private String queueNameLocation;

    @Override
    public <T> T postResult(T t) {

        //发送中间结果到redis
        return null;
    }
}
